package com.test.myrxjava.core;

public interface Emitter<T> {//事件发射接口

    void onNext(T t);

    void onComplete();

    void onError(Throwable throwable);

}
